package com.yrc.test.config;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * Description: KafkaConfig
 *
 * @author: YeRuichang
 * @version: 1.0
 * Create at: 2020/3/24 18:33
 * _
 * Copyright:   Copyright (c)2020
 * Company:     songxiaocai
 * _
 * Modification History:
 * Date              Author      Version     Description
 * ------------------------------------------------------------------
 * 2020/3/24 18:33   YeRuichang    1.0
 */
@Component
public class KafkaConfig {

    @KafkaListener(topics = {"HelloWorld"}, groupId = "yrc2")
    public void receive(String message){
        System.out.println("app_log--消费消息:" + message);
    }
}
